﻿namespace Fetches.Fetch.PagePool.Consume
{
    public interface IProcessCoordinator
    {
        void Initialize(string config, long uniqueId);
        bool IsEmpty();
        /// <summary>
        /// 通过去除重复来实现分布式情况下消费的协同
        /// </summary>
        /// <param name="pageIndex"></param>
        void EnqueueWhenNoDuplicate(int pageIndex);
        int Dequeue();
    }
}
